package com.demo.producer;

import org.apache.kafka.clients.producer.ProducerRecord;

/**
 * @Description: kafkaProducer回调之后的处理
 * @author: fanfan
 */
public interface KafkaProducerCallBack<K,V> {

    /**
     * @Description: producer发送成功后的业务处理
     * @author: fanfan
     * @param record
     */
    void onSuccess(ProducerRecord<K, V> record);

    /**
     * @Description: producer发送成功后的业务处理
     * @author: fanfan
     * @param record
     */
    void onError(ProducerRecord<K, V> record, Exception e);

}
